Notes/Domino 6 and 7 Forum : RE: Java agent ans WAS5

Sriram, I don't know where you get your information from (how Threads are used in agents), but this solved my problem.

I've been trying to connect to a JBoss 2.4.8 server's JMS and using the ThreadGroup technique I finally got it working. I don't know if this is what you meant, but here's how I did it, for anyone interested:

First off, I am running on a domino 6 client for development. I added a lot of JBoss jar files to the Lotus\Notes6\jvm\lib\ext directory. You need these avaiable.

import lotus.domino.*;

import java.util.Properties;

import javax.naming.Context;
import javax.naming.InitialContext;

import javax.jms.Message;
import javax.jms.Queue;
import javax.jms.QueueConnection;
import javax.jms.QueueConnectionFactory;
import javax.jms.QueueSender;
import javax.jms.QueueSession;

public class JavaAgent extends AgentBase {

private class ThreadContents implements Runnable {
public void run() {
try {
String providerUrl = "xxx.xxx.xxx.xxx:1099"; // JBoss server ip address and port
String contextFactory = "org.jnp.interfaces.NamingContextFactory";
String urlPkgPrefixes = "org.jboss.naming";
String queueName = "queue/testQueue";

Properties properties = new Properties();
properties.put(Context.INITIAL_CONTEXT_FACTORY, contextFactory);
properties.put(Context.PROVIDER_URL, providerUrl);
properties.put(Context.URL_PKG_PREFIXES, urlPkgPrefixes);

InitialContext context = new InitialContext(properties);

System.out.println("lookup session");

QueueConnectionFactory factory = (QueueConnectionFactory) context.lookup("QueueConnectionFactory");
QueueConnection connection = factory.createQueueConnection();
QueueSession session = connection.createQueueSession(false, QueueSession.AUTO_ACKNOWLEDGE);

System.out.println("lookup queue");

Queue queue = (Queue) context.lookup(queueName);

System.out.println("sending message");

QueueSender sender = session.createSender(queue);
Message message = session.createTextMessage("this is the message from the domino agent");
sender.send(message);

sender.close();
connection.close();
context.close();

System.out.println("thread done");
}
catch(Exception e) {
e.printStackTrace();
}
}
}

public void NotesMain() {
try {
Session notessession = getSession();
AgentContext agentContext = notessession.getAgentContext();

ThreadGroup group = new ThreadGroup("externalgroup");

Thread t = new Thread(group, new ThreadContents());
t.start();
t.join();

if (group != null && !group.isDestroyed()) {
System.out.println("destroying thread group");
group.destroy();
}

System.out.println("agent done");
} catch(Exception e) {
e.printStackTrace();
}
}
}

Notes/Domino 6 and 7 Forum

Document Options

Search this forum

Forum views and search

Member Tools

RSS Feeds